package observable.emitter

/**
 * 发射器，用于给观察者发送消息
 */
interface Emitter<T> {
    /**
     * 被观察者发送消息
     */
    fun onNext(obj: T)

    fun onError(throwable: Throwable)

    fun onComplete()
}